# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.sensors.date_time_sensor import DateTimeSensor


time_after_04_00 = DateTimeSensor(
    task_id='time_after_04_00',
    pool='unlimited_pool',
    target_time='{{ execution_date | date_add(1) | cst_ds }}T04:00:00+08:00',
    retries=0,
    mode='poke',
    execution_timeout=timedelta(hours=5),
    email=['yl_bigdata@yl-scm.com','time_sensor@yl-scm.com'],
)

